627ad389750460baf5263109856d87511a1b6800,src/test/java/com/metamx/emitter/core/EmitterTest.java,EmitterTest,testFailedEmission,#,239

Before Change


          }
        }.times(1)
    );
    emitter.emit(new UnitEvent("test", 1));
    waitForEmission(emitter);
    Assert.assertTrue(httpClient.succeeded());

After Change


        }.times(1)
    );

    emitter.emit(event2);
    waitForEmission(emitter);

    // Nothing should be queued up, since everything has succeeded.